package pool;

public class Producer implements Runnable {

    private Pot pot;

    public Producer(Pot pot) {
        this.pot = pot;
    }

    @Override
    public void run() {
        while(true){
            synchronized (pot) {
                //不停的做馒头。。。
                //判断什么时候就不做了。
                if (Pot.COUNT >= 100) {
                    break;
                }
                //怎么判断锅填满了呢。
                if (pot.getPot().size() == Pot.MAX_LEN) {
                    //妈妈就进入等待队列了，等待儿子吃馒头。
                    System.out.println("锅里馒头满了，等待儿子吃馒头....");
                    try {
                        //可以换线儿子吃馒头。
                        pot.notifyAll();
                        pot.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    //可以换线儿子吃馒头。
                    pot.notifyAll();
                    pot.makeCake();
                }
            }

        }
    }
}
